package com.automannn.websoketmqtt.consumer.receiver.topic;

import com.automannn.websoketmqtt.common.amqp.TopicGlobalValue;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Map;

/**
 * @author chenkh
 * @time 2020/10/13 11:39
 */
@Component
@RabbitListener(queues = TopicGlobalValue.WOMAN)
public class TopicWomanReceiver {

    @RabbitHandler
    public void process(Map myMessage){
        System.out.println("TopicWomanReceiver消费者收到消息: "+myMessage.toString());
    }

}
